package com.gzhryc.common.kafka;

import java.util.Properties;

/**
 * KafkaConsumer定义
 * @author zhanghao
 *
 */
public interface JFKafkaConsumer {
	
	public String getTopic();
	
	public String getGroupId();
	
	public void start(Properties properties);
	
	public void close();
}
